package com.mbyte.easy.admin.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * @author zte
 * @since 2021/1/20 22:26
 */
@Controller
@RequestMapping("/mq")
public class MQTestController {

//    @Autowired
//    private MQSender mqSender;

    /**
     * 测试mq发送消息(简单模式)
     */
    @RequestMapping("/mq")
    @ResponseBody
    public void mq(){
//        mqSender.send("mqTest");
    }

    /**
     * 测试mq发送消息(Fanout模式)
     */
    @RequestMapping("/mqFanout")
    @ResponseBody
    public void mqFanout(){
//        mqSender.sendFanout("mqTest");
    }

    /**
     * Topic模式
     */
    @RequestMapping("/mqTopic")
    @ResponseBody
    public void mqTopicOne(){
//        mqSender.sendTopicOne("FirstMsg");
    }
    @RequestMapping("/mqTopic/two")
    @ResponseBody
    public void mqTopicTwo(){
//        mqSender.sendTopicTwo("allMsg");
    }


}
